package com.cn.util.custom.queue;

import java.util.concurrent.LinkedBlockingQueue;

public class DataBlockingQueue<E> extends LinkedBlockingQueue<E> {
	private static final long serialVersionUID = 2730906774643847334L;
	
	private boolean isPutData = true; //是否继续放数据
	
	public DataBlockingQueue(){
		super();
	}
	
	public DataBlockingQueue(int capacity){
		super(capacity);
	}
	
	public boolean isPutData() {
		return isPutData;
	}
	public void setPutData(boolean isPutData) {
		this.isPutData = isPutData;
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		DataBlockingQueue queue = new DataBlockingQueue(1000);
		
	}

}
